package com.cjq.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.Queue;
import javax.jms.Topic;

/**
 * @author junqiancai@foxmail.com
 * @since 2021/6/22 0:52
 */

@RestController
//生产者
public class Producer {
//    //注入存放消息的队列，用于下列方法一
//    @Autowired
//    private Queue queue;
//
//    //注入springboot封装的工具类
//    @Autowired
//    private JmsMessagingTemplate jmsMessagingTemplate;
//
//    @RequestMapping("send")
//    public void send(String name) {
//        //方法一：添加消息到消息队列
//        jmsMessagingTemplate.convertAndSend(queue, name);
//        //方法二：这种方式不需要手动创建queue，系统会自行创建名为test的队列
//        //jmsMessagingTemplate.convertAndSend("test", name);
//    }

//
//    @Autowired
//    private JmsMessagingTemplate jmsTemplate;
//
//    @Autowired
//    private Queue queue;
//
//    @Autowired
//    private Topic topic;
//
//    //发送queue类型消息
//    @GetMapping("/queue")
//    public void sendQueueMsg(String msg){
//        jmsTemplate.convertAndSend(queue, msg);
//    }
//
//    //发送topic类型消息
//    @GetMapping("/topic")
//    public void sendTopicMsg(String msg){
//        jmsTemplate.convertAndSend(topic, msg);
//    }
}